package com.wyy.test.akkaimpl;

import java.util.concurrent.Executor;

/**
 * @Date 2024/7/31
 * @Author wyy
 **/
public class MyActor extends AbstractActor{

    public MyActor(Executor executor) {
        super(executor);
    }

    @Override
    public void onReceive(Object message) {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        System.out.println("message = " + message);
    }
}
